//package com.example.java.kafka.es9client;
//
//import co.elastic.clients.elasticsearch.core.GetResponse;
//import co.elastic.clients.elasticsearch.core.UpdateResponse;
//
//public class UpdateDoc {
//    public static void main(String[] args) {
//        ConnectElasticsearch.connect(client -> {
//            GetResponse<User> getResponse1 = client.get(g -> g
//                            .index("user")
//                            .id("1001"),
//                    User.class
//            );
//            System.out.println("Update before: " + getResponse1);
//            UpdateResponse<User> updateResponse = client.update(u -> u
//                .index("user")
//                .id("1001")
//                .docAsUpsert(true)
//                .doc(new User() {{
//                    setSex("女");
//                }}),
//                User.class
//            );
//            System.out.println("Updating: " + updateResponse);
//            GetResponse<User> getResponse2 = client.get(g -> g
//                            .index("user")
//                            .id("1001"),
//                    User.class
//            );
//            System.out.println("Update after: " + getResponse2);
//        });
//    }
//}
